# -*- coding: utf-8 -*-
from airflow.operators.dummy_operator import DummyOperator

from jms_route_test.dm.dm_route_whole_base_dt.huadong import dm__dm_route_whole_huadong_base
from jms_route_test.dm.dm_route_whole_base_dt.huanan import dm__dm_route_whole_huanan_base

dm__dm_route_whole_base_dt = DummyOperator(
    task_id='dm__dm_route_whole_base_dt',
    pool='unlimited_pool',
    priority_weight=0,
    email=['zhangqinglin@jtexpress.com','yl_bigdata@yl-scm.com'],
)
dm__dm_route_whole_base_dt << [
                       dm__dm_route_whole_huadong_base,
                       dm__dm_route_whole_huanan_base,
                       ]
